package com.wg.dome;

import cn.hutool.log.Log;
import cn.hutool.log.LogFactory;
import com.wg.common.net.OperationRequest;
import com.wg.common.net.OperationResponse;
import com.wg.common.net.SendParameters;
import com.wg.net.AbstractOutboundRpcPeer;
import com.wg.net.BaseApplication;
import com.wg.net.DisconnectReason;

/**
 * @author 少爷123
 */
public class TestRpcPeer extends AbstractOutboundRpcPeer {
    private static final Log log = LogFactory.get();
    public TestRpcPeer(BaseApplication application) {
        super(application);
    }

    @Override
    protected void onConnectionEstablished(Object responseObject) {
        log.info("onConnectionEstablished");
    }

    @Override
    protected void onConnectionFailed(int errorCode, String errorMessage) {
        log.info("onConnectionFailed");

    }

    @Override
    protected void onOperationResponse(OperationResponse operationResponse, SendParameters sendParameters) {

    }

    @Override
    protected void onOperationRequest(OperationRequest request, SendParameters sendParameters) {

    }

    @Override
    protected void onDisconnect(DisconnectReason reasonCode, String reasonDetail) {
        log.info("onDisconnect");

    }
}
